import mysql from 'mysql'
import { MYSQL_CONF } from '../conf/db.js'

// 创建连接对象
const con = mysql.createConnection(MYSQL_CONF)

con.connect()

// 统一执行 sql 的函数
function execSql(sql) {
	return new Promise((resolve, reject) => {
		con.query(sql, (err, result) => {
			if (err) {
				reject(err)
				return
			}
			resolve(result)
		})
	})
}

const escape = mysql.escape

export { execSql, escape }
